package rxjava2.groccery

import io.reactivex.Flowable
import io.reactivex.internal.schedulers.ImmediateThinScheduler
import io.reactivex.schedulers.Schedulers
import java.util.concurrent.TimeUnit

/**
 * Created by SEELE on 2018/6/22.
 */
val ATTR_ONE = 1
val ATTR_SEC = 1 shl 2
val ATTRS = arrayListOf(ATTR_ONE,
        ATTR_SEC
)

fun main(args: Array<String>) {
    val StateSet = Array(ATTRS.size) { IntArray(3) }

    Flowable
            .interval(1, TimeUnit.SECONDS)
            .subscribe({
                println(it)
            }, {
                it.printStackTrace()
            }, {

            })
}